package com.company.messagequeue.kafka.constant;

import com.company.messagequeue.kafka.producer.KafkaProducerClient;

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

/**
 * Title: KafkaConstant<br>
 * Description: KafkaConstant<br>
 * CreateDate:2020年12月05日 13:55
 *
 */
public class KafkaConstant {
  /**
   * 默认生产者名称
   */
  public static final String DEFAULT_PRODUCER_NAME = "KafkaPublicProducer";

  /**
   * 默认生产者名称
   */
  public static final String WARNING_MESSAGE_RECEIVER;

  /**
   * kafka服务器地址,这里直用文件方式读取配置文件，直接在类加载的时候读取一次就好
   */
  public static final String SERVER_ADDRESS;

  static {
    Properties properties = new Properties();
    // 使用ClassLoader加载properties配置文件生成对应的输入流
    InputStream in = KafkaProducerClient.class.getClassLoader().getResourceAsStream(
        "application.properties");
    // 使用properties对象加载输入流
    try {
      properties.load(in);
    } catch (IOException e) {
      e.printStackTrace();
    }
    // 获取key对应的value值
    SERVER_ADDRESS = properties.getProperty("kafka.bootstrap.servers");

    WARNING_MESSAGE_RECEIVER = properties.getProperty("kafka.warning.workwechatlist");
  }
}
